ef249becdc78394e1a4a6ea05735e80bae8f6477,hadoop/src/main/java/water/hadoop/h2omapper.java,EmbeddedH2OConfig,fetchFlatfile,#,166

Before Change


      DriverToMapperMessage msg2 = new DriverToMapperMessage();
      msg2.read(s);
      if (msg2.getType() != DriverToMapperMessage.TYPE_FETCH_FLATFILE_RESPONSE) {
        Log.err("DriverToMapperMessage type unrecognized");
        throw new Exception ("DriverToMapperMessage type unrecognized");
      }
      s.close();

After Change


      if (type != DriverToMapperMessage.TYPE_FETCH_FLATFILE_RESPONSE) {
        int typeAsInt = (int)type & 0xff;
        String str = new String("DriverToMapperMessage type unrecognized (" + typeAsInt + ")");
        Log.err(str);
        throw new Exception (str);
      }
      s.close();